package com.lsh.controller;

import com.lsh.service.RabbitService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author ：LiuShihao
 * @date ：Created in 2021/3/18 9:54 下午
 * @desc ：
 */
@RestController
@RequestMapping("/mq")
public class RabbitController {



    @Autowired
    RabbitService rabbitService;

    /**
     * consumer：
     * 1.扣减金额
     * 2.发送消息到MQ
     *
     * provider：
     * 1.监听mq
     * 2.扣减库存，如果发生异常，则重新投递消息。
     *
     * @return
     */
    @GetMapping("ConsumerAndSendToRabbit")
    public String Consumer(){
        try {
            rabbitService.Consumer();
        }catch (Exception e){
            return "fail";
        }
        return "seccuss";

    }
}
